package com.atguigu.day02;

import org.apache.flink.util.MathUtils;

public class Example8 {
    public static void main(String[] args) {
        // key是1
        int key = 2;
        // 第一步：获取key的hashCode
        var hashCode = Integer.hashCode(key);
        System.out.println(hashCode);
        // 第二步：根据hashCode计算Murmurhash
        var murmurHash = MathUtils.murmurHash(hashCode);
        System.out.println(murmurHash);
        // 第三步：计算将数据发送到reduce的并行子任务的索引
        // reduce的并行度：4, flink的默认最大并行度是128
        var idx = (murmurHash % 128) * 4 / 128;

        System.out.println(idx);
    }
}
